package com.yc.streamamq.consumer;

import com.yc.streamamq.util.SinkIn;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;

@Component
public class ReceiveMessage {

    @StreamListener(SinkIn.INPUT)
    public void receiveSucceed_v1(String message) {
        String msg = "消息接收成功>>>" + message;
        System.out.println(msg);
    }

}
